package cn.zzuli.springboot.produce;

import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import javax.jms.Queue;

@Component
public class QueueProduce {
    @Resource
    private JmsMessagingTemplate jmsMessagingTemplate;

    /**
     * 使用自定义的queue-->在配置类配置的queue
     */
    @Resource
    private Queue queue;

    public void produceMSG(){
        jmsMessagingTemplate.convertAndSend(queue,"--->这是与spring boot整合的JMS");
    }

    /**
     * 定时投递消息,每隔3秒自动发送消息
     */
    @Scheduled(fixedDelay = 3000)
    public void produceMSGScheduled(){
        jmsMessagingTemplate.convertAndSend(queue,"--->定时投放    这是与spring boot整合的JMS");
    }
}
